// +----------------------------------------------------------------------
// | JavaWeb_EleVue_Pro前后端分离旗舰版框架 [ JavaWeb ]
// +----------------------------------------------------------------------
// | 版权所有 2021 上海JavaWeb研发中心
// +----------------------------------------------------------------------
// | 官方网站: http://www.javaweb.vip/
// +----------------------------------------------------------------------
// | 作者: 鲲鹏 <javaweb520@gmail.com>
// +----------------------------------------------------------------------
// | 免责声明:
// | 本软件框架禁止任何单位和个人用于任何违法、侵害他人合法利益等恶意的行为，禁止用于任何违
// | 反我国法律法规的一切平台研发，任何单位和个人使用本软件框架用于产品研发而产生的任何意外
// | 、疏忽、合约毁坏、诽谤、版权或知识产权侵犯及其造成的损失 (包括但不限于直接、间接、附带
// | 或衍生的损失等)，本团队不承担任何法律责任。本软件框架只能用于公司和个人内部的法律所允
// | 许的合法合规的软件产品研发，详细声明内容请阅读《框架免责声明》附件；
// +----------------------------------------------------------------------

package com.javaweb.admin.service.impl;

import cn.hutool.core.convert.Convert;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.javaweb.admin.query.C37InfCkGttzdBillQuery;
import com.javaweb.admin.vo.c37infckgttzdbill.C37InfCkGttzdBillListVo;
import com.javaweb.common.config.CommonConfig;
import com.javaweb.common.config.DataSourceType;
import com.javaweb.common.config.SpecifyDataSource;
import com.javaweb.common.utils.CommonUtils;
import com.javaweb.common.common.BaseQuery;
import com.javaweb.common.common.BaseServiceImpl;
import com.javaweb.admin.constant.CommercialAcquisitionReportConstant;
import com.javaweb.admin.entity.CommercialAcquisitionReport;
import com.javaweb.admin.mapper.CommercialAcquisitionReportMapper;
import com.javaweb.admin.query.CommercialAcquisitionReportQuery;
import com.javaweb.admin.service.ICommercialAcquisitionReportService;
import com.javaweb.common.utils.StringUtils;
import com.javaweb.system.utils.ShiroUtils;
import com.javaweb.admin.vo.commercialacquisitionreport.CommercialAcquisitionReportInfoVo;
import com.javaweb.admin.vo.commercialacquisitionreport.CommercialAcquisitionReportListVo;
import com.javaweb.common.utils.DateUtils;
import com.javaweb.common.utils.JsonResult;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.Serializable;
import java.util.*;

/**
  * <p>
  * 收购报表 服务类实现
  * </p>
  *
  * @author 鲲鹏
  * @since 2023-05-12
  */
@Service
public class CommercialAcquisitionReportServiceImpl extends BaseServiceImpl<CommercialAcquisitionReportMapper, CommercialAcquisitionReport> implements ICommercialAcquisitionReportService {

    @Autowired
    private CommercialAcquisitionReportMapper commercialAcquisitionReportMapper;

    /**
     * 获取数据列表
     *
     * @param query 查询条件
     * @return
     */
    @Override
    @SpecifyDataSource(value = DataSourceType.BIP)
    public JsonResult getList(BaseQuery query) {
        CommercialAcquisitionReportQuery commercialAcquisitionReportQuery = (CommercialAcquisitionReportQuery) query;
        // 查询条件
        QueryWrapper<CommercialAcquisitionReport> queryWrapper = new QueryWrapper<>();
        queryWrapper.select("id,yearly,monthly,purchase_code,sale_code,material_code,purchase_num,purchase_amount,purchase_margin,data_source,bip_id,creator,create_time,modifier,modify_time,mark,syn_status,two_vote_num,not_two_vote_num,two_vote_money,not_two_vote_money");
        if(!StringUtils.isEmpty(commercialAcquisitionReportQuery.getYearly()))
        {
            queryWrapper.eq("yearly",commercialAcquisitionReportQuery.getYearly());
        }
        if(!StringUtils.isEmpty(commercialAcquisitionReportQuery.getPurchaseCode()))
        {
            queryWrapper.eq("purchase_code",commercialAcquisitionReportQuery.getPurchaseCode());
        }
        if(!StringUtils.isEmpty(commercialAcquisitionReportQuery.getSaleCode()))
        {
            queryWrapper.eq("sale_code",commercialAcquisitionReportQuery.getSaleCode());
        }
        if(!StringUtils.isEmpty(commercialAcquisitionReportQuery.getMaterialCode()))
        {
            queryWrapper.eq("material_code",commercialAcquisitionReportQuery.getMaterialCode());
        }
        if(!StringUtils.isEmpty(commercialAcquisitionReportQuery.getSynStatus()))
        {
            queryWrapper.eq("syn_status",commercialAcquisitionReportQuery.getSynStatus());
        }
        queryWrapper.orderByDesc("id");


        // 获取数据列表
        IPage<CommercialAcquisitionReport> page = new Page<>(commercialAcquisitionReportQuery.getPage(), commercialAcquisitionReportQuery.getLimit());
        if(commercialAcquisitionReportQuery.getLimit()>500) {
            page.setSize(-1);
        }
        IPage<CommercialAcquisitionReport> pageData = commercialAcquisitionReportMapper.selectPage(page, queryWrapper);
        pageData.convert(x -> {
            CommercialAcquisitionReportListVo commercialAcquisitionReportListVo = Convert.convert(CommercialAcquisitionReportListVo.class, x);
            return commercialAcquisitionReportListVo;
        });
        return JsonResult.success(pageData);
    }

    @Override
    @SpecifyDataSource(value = DataSourceType.BIP)
    public JsonResult GetReportList(BaseQuery query) {
        CommercialAcquisitionReportQuery commercialAcquisitionReportQuery = (CommercialAcquisitionReportQuery) query;

        // 获取数据列表
        if(commercialAcquisitionReportQuery.getPage()==null)
        {
            commercialAcquisitionReportQuery.setPage(1);
            commercialAcquisitionReportQuery.setLimit(100000);
        }
        IPage<CommercialAcquisitionReportListVo> page = new Page<>(commercialAcquisitionReportQuery.getPage(), commercialAcquisitionReportQuery.getLimit());
        if(commercialAcquisitionReportQuery.getLimit()>500) {
            page.setSize(-1);
        }
        IPage<CommercialAcquisitionReportListVo> pageData = commercialAcquisitionReportMapper.GetReportList(page, commercialAcquisitionReportQuery);
//        pageData.convert(x -> {
//            C37InfRkCgddBillListVo c37InfRkCgddBillListVo = Convert.convert(C37InfRkCgddBillListVo.class, x);
//            return c37InfRkCgddBillListVo;
//        });
        return JsonResult.success(pageData);
    }

    @Override
    @SpecifyDataSource(value = DataSourceType.BIP)
    public JsonResult getYearList() {
        List<String> list = commercialAcquisitionReportMapper.getYearList();
        return  JsonResult.success(list);
    }

    @Override
    public JsonResult getMonthList() {
        return null;
    }

    @Override
    @SpecifyDataSource(value = DataSourceType.BIP)
    public JsonResult removeReportData(String yearly, String monthly) {
        try {
            Map<String, Object> param = new HashMap<>();
            param.put("yearly", yearly);
            if(!StringUtils.isEmpty(monthly)) {
                param.put("monthly", monthly);
            }
            commercialAcquisitionReportMapper.deleteByMap(param);
            return JsonResult.success();
        }
        catch(Exception ex)
        {
            return JsonResult.error(ex.getMessage());
        }
    }

    /**
     * 获取详情Vo
     *
     * @param id 记录ID
     * @return
     */
    @Override
    public Object getInfo(Serializable id) {
        CommercialAcquisitionReport entity = (CommercialAcquisitionReport) super.getInfo(id);
        // 返回视图Vo
        CommercialAcquisitionReportInfoVo commercialAcquisitionReportInfoVo = new CommercialAcquisitionReportInfoVo();
        // 拷贝属性
        BeanUtils.copyProperties(entity, commercialAcquisitionReportInfoVo);
        return commercialAcquisitionReportInfoVo;
    }

    /**
     * 添加、更新记录
     *
     * @param entity 实体对象
     * @return
     */
    @Override
    @SpecifyDataSource(value = DataSourceType.BIP)
    public JsonResult edit(CommercialAcquisitionReport entity) {
        if (StringUtils.isNotNull(entity.getId()) && entity.getId() > 0) {
        } else {
            entity.setCreateTime(DateUtils.now());
        }
        return super.edit(entity);
    }

    /**
     * 删除记录
     *
     * @param entity 实体对象
     * @return
     */
    @Override
    public JsonResult delete(CommercialAcquisitionReport entity) {
        entity.setMark(0);
        return super.delete(entity);
    }

}